package com.feng.thread.concurrent;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * 在Java 5之后，任务分两类： 一类是实现了Runnable接口的类， 一类是实现了Callable接口的类。
 * 两者都可以被ExecutorService执行，但是Runnable任务没有返回值，而Callable任务有返回值。
 * 并且Callable的call()方法只能通过ExecutorService的submit(Callable<T> task) 方法来执行， 并且返回一个
 * <T>Future<T>，是表示任务等待完成的 Future。 Runnable
 * 不会返回结果，并且无法抛出经过检查的异常而Callable又返回结果，而且当获取返回结果时可能会抛出异常。
 * Callable中的call()方法类似Runnable的run()方法，区别同样是有返回值，后者没有。
 * 
 * @author Qian
 *
 */
public class CallableDemo {

	public static void main(String[] args) {
		ExecutorService executor = Executors.newCachedThreadPool();
		List<Future<String>> resultList = new ArrayList<Future<String>>();
		for (int i = 0; i < 10; i++) {
			// 使用ExecutorService执行Callable类型的任务，并将结果保存在future变量中
			Future<String> futureList = executor.submit(new FutureTest(i));
			// 将任务执行结果存储到List中
			resultList.add(futureList);
		}
		for (Future<String> future : resultList) {
			try {
				// Future返回如果没有完成，则一直循环等待，直到Future返回完成 .如果任务已完成，则返回 true
				// while (!future.isDone());
				System.out.println(future.isDone());
				// 打印各个线程（任务）执行的结果.如果Future的返回尚未完成，则get（）方法会阻塞等待，直到Future完成返回
				System.err.println(future.get());
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (ExecutionException e) {
				e.printStackTrace();
			} finally {
				// 启动一次顺序关闭，执行以前提交的任务，但不接受新任务
				executor.shutdown();
			}
		}
	}

}

class FutureTest implements Callable<String> {
	private int id;

	public FutureTest(int id) {// 构造函数传值
		this.id = id;
	}
	/**
	 * 任务的具体过程，一旦任务传给ExecutorService的submit方法， 则该方法自动在一个线程上执行
	 */
	@Override
	public String call() throws Exception {
		System.out.println("call()方法被自动调用了啊啊啊啊啊--" + Thread.currentThread().getName());
		// 该返回结果将被Future的get方法得到
		return "call()方法被自动调用，返回的结果是---" + id + "---" + Thread.currentThread().getName();
	}

}
